a1ccce3b5c703e9084b4961a96bb639d05895fda,contrib/extensions/replication/core/src/test/java/org/apache/sling/replication/queue/impl/PriorityPathQueueDistributionStrategyTest.java,PriorityPathQueueDistributionStrategyTest,testPackageAdditionWithSucceedingItemDeliveryOnPriorityPath,#,65

Before Change


        when(properties.get("priority.paths")).thenReturn(new String[]{"/content", "/apps"});
        when(context.getProperties()).thenReturn(properties);
        priorityPathDistributionStrategy.activate(context);
        ReplicationQueueItem replicationPackage = mock(ReplicationQueueItem.class);
        when(replicationPackage.getPaths()).thenReturn(new String[]{"/content/sample1"});
        ReplicationQueueProvider queueProvider = mock(ReplicationQueueProvider.class);
        ReplicationQueue queue = mock(ReplicationQueue.class);
        when(queueProvider.getQueue("agentName", "/content")).thenReturn(queue);
        when(queue.add(replicationPackage)).thenReturn(true);
        ReplicationQueueItemState state = mock(ReplicationQueueItemState.class);
        when(state.isSuccessful()).thenReturn(true);
        when(queue.getStatus(replicationPackage)).thenReturn(state);
        ReplicationQueueItemState returnedState = priorityPathDistributionStrategy.add("agentName", replicationPackage, queueProvider);
        assertNotNull(returnedState);
        assertTrue(returnedState.isSuccessful());

After Change


        ReplicationQueueProvider queueProvider = mock(ReplicationQueueProvider.class);
        ReplicationQueue queue = mock(ReplicationQueue.class);
        when(queueProvider.getQueue("agentName", "/content")).thenReturn(queue);
        when(queue.add(any(ReplicationQueueItem.class))).thenReturn(true);

        boolean returnedState = priorityPathDistributionStrategy.add("agentName", replicationPackage, queueProvider);
        assertTrue(returnedState);